//package cn.iocoder.yudao.module.mqtt.service;
//
//import cn.iocoder.yudao.module.mqtt.framework.geteway.MqttGateway;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//@Component
//public class MqttMessageSender {
//
//    @Autowired
//    private MqttGateway mqttGateway ;
//
//    public void sendMsg(String topic , String msg) {
//        mqttGateway.sendMsgToMqtt(topic , msg);
//    }
//
//    public void sendMsg(String topic , int qos ,  String msg) {
//        mqttGateway.sendMsgToMqtt(topic , qos ,  msg);
//    }
//
//}
